🎖️GitЯра🎖️ - /page/blob.mu

T8b949e/*

*

* This program is free software: you can redistribute it and/or modify

* it under the terms of the GNU General Public License as published by

* the Free Software Foundation, either version 3 of the License, or

* (at your option) any later version.

*

* This program is distributed in the hope that it will be useful,

* but WITHOUT ANY WARRANTY; without even the implied warranty of

* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the

* GNU General Public License for more details.

*

* You should have received a copy of the GNU General Public License

* along with this program. If not, see <https://www.gnu.org/licenses/>.

*/

Tff7b72package T7ee787org.meshtastic.core.data.manager

Tff7b72import T7ee787co.touchlab.kermit.Logger

Tff7b72import T7ee787kotlinx.coroutines.CoroutineScope

Tff7b72import T7ee787kotlinx.coroutines.Job

Tff7b72import T7ee787kotlinx.coroutines.flow.launchIn

Tff7b72import T7ee787kotlinx.coroutines.flow.onEach

Tff7b72import T7ee787kotlinx.coroutines.launch

Tff7b72import T7ee787kotlinx.coroutines.sync.Mutex

Tff7b72import T7ee787kotlinx.coroutines.sync.withLock

Tff7b72import T7ee787org.koin.core.annotation.Named

Tff7b72import T7ee787org.koin.core.annotation.Single

Tff7b72import T7ee787org.meshtastic.core.common.util.handledLaunch

Tff7b72import T7ee787org.meshtastic.core.common.util.nowMillis

Tff7b72import T7ee787org.meshtastic.core.common.util.nowSeconds

Tff7b72import T7ee787org.meshtastic.core.model.MeshLog

Tff7b72import T7ee787org.meshtastic.core.model.Node

Tff7b72import T7ee787org.meshtastic.core.model.util.isLora

Tff7b72import T7ee787org.meshtastic.core.model.util.toOneLineString

Tff7b72import T7ee787org.meshtastic.core.model.util.toPIIString

Tff7b72import T7ee787org.meshtastic.core.repository.FromRadioPacketHandler

Tff7b72import T7ee787org.meshtastic.core.repository.MeshLogRepository

Tff7b72import T7ee787org.meshtastic.core.repository.MeshMessageProcessor

Tff7b72import T7ee787org.meshtastic.core.repository.MeshRouter

Tff7b72import T7ee787org.meshtastic.core.repository.NodeManager

Tff7b72import T7ee787org.meshtastic.core.repository.ServiceRepository

Tff7b72import T7ee787org.meshtastic.proto.FromRadio

Tff7b72import T7ee787org.meshtastic.proto.LogRecord

Tff7b72import T7ee787org.meshtastic.proto.MeshPacket

Tff7b72import T7ee787org.meshtastic.proto.PortNum

Tff7b72import T7ee787kotlin.concurrent.Volatile

Tff7b72import T7ee787kotlin.uuid.Uuid

T8b949e/** Implementation of [MeshMessageProcessor] that handles raw radio messages and prepares mesh packets for routing. */

Tf0883e@SuppressTb4b4b4(Ta5d6ff"Ta5d6ffTooManyFunctionsTa5d6ff"Tb4b4b4)

Tf0883e@Single

Tff7b72class T56d364MeshMessageProcessorImplTb4b4b4(

Tff7b72private Tff7b72val Te6edf3nodeManagerTb4b4b4: Te6edf3NodeManagerTb4b4b4,

Tff7b72private Tff7b72val Te6edf3serviceRepositoryTb4b4b4: Te6edf3ServiceRepositoryTb4b4b4,

Tff7b72private Tff7b72val Te6edf3meshLogRepositoryTb4b4b4: Te6edf3LazyTff7b72<Te6edf3MeshLogRepositoryTff7b72>Tb4b4b4,

Tff7b72private Tff7b72val Te6edf3routerTb4b4b4: Te6edf3LazyTff7b72<Te6edf3MeshRouterTff7b72>Tb4b4b4,

Tff7b72private Tff7b72val Te6edf3fromRadioDispatcherTb4b4b4: Te6edf3FromRadioPacketHandlerTb4b4b4,

Tf0883e@NamedTb4b4b4(Ta5d6ff"Ta5d6ffServiceScopeTa5d6ff"Tb4b4b4) Tff7b72private Tff7b72val Te6edf3scopeTb4b4b4: Te6edf3CoroutineScopeTb4b4b4,

Tb4b4b4) Tb4b4b4: Te6edf3MeshMessageProcessor Tb4b4b4{

Tff7b72private Tff7b72val Te6edf3mapsMutex Tff7b72= Te6edf3MutexTb4b4b4(Tb4b4b4)

Tff7b72private Tff7b72val Te6edf3logUuidByPacketId Tff7b72= Te6edf3mutableMapOfTff7b72<Tffa657IntTb4b4b4, Tffa657StringTff7b72>Tb4b4b4(Tb4b4b4)

Tff7b72private Tff7b72val Te6edf3logInsertJobByPacketId Tff7b72= Te6edf3mutableMapOfTff7b72<Tffa657IntTb4b4b4, Te6edf3JobTff7b72>Tb4b4b4(Tb4b4b4)

T8b949e/**

* Epoch-millisecond timestamp of the last local-node `lastHeard` DB write. Used to throttle updates to at most once

* per [LOCAL_NODE_REFRESH_INTERVAL_MS] so that high-frequency FromRadio variants (log records, queue status) don't

* flood the DB.

*/

Tf0883e@Volatile Tff7b72private Tff7b72var Te6edf3lastLocalNodeRefreshMs Tff7b72= T79c0ff0L

Tff7b72private Tff7b72val Te6edf3earlyMutex Tff7b72= Te6edf3MutexTb4b4b4(Tb4b4b4)

Tff7b72private Tff7b72val Te6edf3earlyReceivedPackets Tff7b72= Te6edf3ArrayDequeTff7b72<Te6edf3MeshPacketTff7b72>Tb4b4b4(Tb4b4b4)

Tff7b72private Tff7b72val Te6edf3maxEarlyPacketBuffer Tff7b72= T79c0ff1T79c0ff0T79c0ff2T79c0ff4T79c0ff0

Tff7b72override Tff7b72fun Td2a8ffclearEarlyPacketsTb4b4b4(Tb4b4b4) Tb4b4b4{

Te6edf3scopeTb4b4b4.Te6edf3launch Tb4b4b4{ Te6edf3earlyMutexTb4b4b4.Te6edf3withLock Tb4b4b4{ Te6edf3earlyReceivedPacketsTb4b4b4.Te6edf3clearTb4b4b4(Tb4b4b4) Tb4b4b4} Tb4b4b4}

Tb4b4b4}

Tff7b72init Tb4b4b4{

Te6edf3nodeManagerTb4b4b4.Te6edf3isNodeDbReady

Tb4b4b4.Te6edf3onEach Tb4b4b4{ Te6edf3ready Tff7b72-Tff7b72>

Tff7b72if Tb4b4b4(Te6edf3readyTb4b4b4) Tb4b4b4{

Te6edf3flushEarlyReceivedPacketsTb4b4b4(Ta5d6ff"Ta5d6ffdbReadyTa5d6ff"Tb4b4b4)

Tb4b4b4}

Tb4b4b4.Te6edf3launchInTb4b4b4(Te6edf3scopeTb4b4b4)

Tb4b4b4}

Tff7b72override Tff7b72fun Td2a8ffhandleFromRadioTb4b4b4(Te6edf3bytesTb4b4b4: Te6edf3ByteArrayTb4b4b4, Te6edf3myNodeNumTb4b4b4: Tffa657Int?Tb4b4b4) Tb4b4b4{

Te6edf3runCatching Tb4b4b4{ Te6edf3FromRadioTb4b4b4.Te6edf3ADAPTERTb4b4b4.Te6edf3decodeTb4b4b4(Te6edf3bytesTb4b4b4) Tb4b4b4}

Tb4b4b4.Te6edf3onSuccess Tb4b4b4{ Te6edf3proto Tff7b72-Tff7b72> Te6edf3processFromRadioTb4b4b4(Te6edf3protoTb4b4b4, Te6edf3myNodeNumTb4b4b4) Tb4b4b4}

Tb4b4b4.Te6edf3onFailure Tb4b4b4{ Te6edf3primaryException Tff7b72-Tff7b72>

Te6edf3runCatching Tb4b4b4{

Tff7b72val Te6edf3logRecord Tff7b72= Te6edf3LogRecordTb4b4b4.Te6edf3ADAPTERTb4b4b4.Te6edf3decodeTb4b4b4(Te6edf3bytesTb4b4b4)

Te6edf3processFromRadioTb4b4b4(Te6edf3FromRadioTb4b4b4(Te6edf3log_record Tff7b72= Te6edf3logRecordTb4b4b4)Tb4b4b4, Te6edf3myNodeNumTb4b4b4)

Tb4b4b4}

Tb4b4b4.Te6edf3onFailure Tb4b4b4{ Te6edf3_ Tff7b72-Tff7b72>

Te6edf3LoggerTb4b4b4.Te6edf3eTb4b4b4(Te6edf3primaryExceptionTb4b4b4) Tb4b4b4{

Ta5d6ff"Ta5d6ffFailed to parse radio packet (len=Tffd700${Te6edf3bytesTb4b4b4.Te6edf3sizeTffd700}Ta5d6ff). Not a valid FromRadio or LogRecord.Ta5d6ff"

Tb4b4b4}

Tff7b72private Tff7b72fun Td2a8ffprocessFromRadioTb4b4b4(Te6edf3protoTb4b4b4: Te6edf3FromRadioTb4b4b4, Te6edf3myNodeNumTb4b4b4: Tffa657Int?Tb4b4b4) Tb4b4b4{

T8b949e// Any decoded FromRadio proves the radio link is alive — keep the local node fresh.

Te6edf3refreshLocalNodeLastHeardTb4b4b4(Tb4b4b4)

T8b949e// Audit log every incoming variant

Te6edf3logVariantTb4b4b4(Te6edf3protoTb4b4b4)

Tff7b72val Te6edf3packet Tff7b72= Te6edf3protoTb4b4b4.Te6edf3packet

Tff7b72if Tb4b4b4(Te6edf3packet Tff7b72!Tff7b72= Tff7b72nullTb4b4b4) Tb4b4b4{

Te6edf3handleReceivedMeshPacketTb4b4b4(Te6edf3packetTb4b4b4, Te6edf3myNodeNumTb4b4b4)

Tb4b4b4} Tff7b72else Tb4b4b4{

Te6edf3fromRadioDispatcherTb4b4b4.Te6edf3handleFromRadioTb4b4b4(Te6edf3protoTb4b4b4)

Tb4b4b4}

Tff7b72private Tff7b72fun Td2a8fflogVariantTb4b4b4(Te6edf3protoTb4b4b4: Te6edf3FromRadioTb4b4b4) Tb4b4b4{

Tff7b72val Tb4b4b4(Te6edf3typeTb4b4b4, Te6edf3messageTb4b4b4) Tff7b72=

Tff7b72when Tb4b4b4{

Te6edf3protoTb4b4b4.Te6edf3log_record Tff7b72!Tff7b72= Tff7b72null Tff7b72-Tff7b72> Ta5d6ff"Ta5d6ffLogRecordTa5d6ff" Te6edf3to Te6edf3protoTb4b4b4.Te6edf3log_recordTb4b4b4.Te6edf3toStringTb4b4b4(Tb4b4b4)

Te6edf3protoTb4b4b4.Te6edf3rebooted Tff7b72!Tff7b72= Tff7b72null Tff7b72-Tff7b72> Ta5d6ff"Ta5d6ffRebootedTa5d6ff" Te6edf3to Te6edf3protoTb4b4b4.Te6edf3rebootedTb4b4b4.Te6edf3toStringTb4b4b4(Tb4b4b4)

Te6edf3protoTb4b4b4.Te6edf3xmodemPacket Tff7b72!Tff7b72= Tff7b72null Tff7b72-Tff7b72> Ta5d6ff"Ta5d6ffXmodemPacketTa5d6ff" Te6edf3to Te6edf3protoTb4b4b4.Te6edf3xmodemPacketTb4b4b4.Te6edf3toStringTb4b4b4(Tb4b4b4)

Te6edf3protoTb4b4b4.Te6edf3deviceuiConfig Tff7b72!Tff7b72= Tff7b72null Tff7b72-Tff7b72> Ta5d6ff"Ta5d6ffDeviceUIConfigTa5d6ff" Te6edf3to Te6edf3protoTb4b4b4.Te6edf3deviceuiConfigTb4b4b4.Te6edf3toStringTb4b4b4(Tb4b4b4)

Te6edf3protoTb4b4b4.Te6edf3fileInfo Tff7b72!Tff7b72= Tff7b72null Tff7b72-Tff7b72> Ta5d6ff"Ta5d6ffFileInfoTa5d6ff" Te6edf3to Te6edf3protoTb4b4b4.Te6edf3fileInfoTb4b4b4.Te6edf3toStringTb4b4b4(Tb4b4b4)

Te6edf3protoTb4b4b4.Te6edf3my_info Tff7b72!Tff7b72= Tff7b72null Tff7b72-Tff7b72> Ta5d6ff"Ta5d6ffMyInfoTa5d6ff" Te6edf3to Te6edf3protoTb4b4b4.Te6edf3my_infoTff7b72!!Tb4b4b4.Te6edf3toOneLineStringTb4b4b4(Tb4b4b4)

Te6edf3protoTb4b4b4.Te6edf3node_info Tff7b72!Tff7b72= Tff7b72null Tff7b72-Tff7b72> Ta5d6ff"Ta5d6ffNodeInfoTa5d6ff" Te6edf3to Te6edf3protoTb4b4b4.Te6edf3node_infoTff7b72!!Tb4b4b4.Te6edf3toPIIStringTb4b4b4(Tb4b4b4)

Te6edf3protoTb4b4b4.Te6edf3config Tff7b72!Tff7b72= Tff7b72null Tff7b72-Tff7b72> Ta5d6ff"Ta5d6ffConfigTa5d6ff" Te6edf3to Te6edf3protoTb4b4b4.Te6edf3configTff7b72!!Tb4b4b4.Te6edf3toOneLineStringTb4b4b4(Tb4b4b4)

Te6edf3protoTb4b4b4.Te6edf3moduleConfig Tff7b72!Tff7b72= Tff7b72null Tff7b72-Tff7b72> Ta5d6ff"Ta5d6ffModuleConfigTa5d6ff" Te6edf3to Te6edf3protoTb4b4b4.Te6edf3moduleConfigTff7b72!!Tb4b4b4.Te6edf3toOneLineStringTb4b4b4(Tb4b4b4)

Te6edf3protoTb4b4b4.Te6edf3channel Tff7b72!Tff7b72= Tff7b72null Tff7b72-Tff7b72> Ta5d6ff"Ta5d6ffChannelTa5d6ff" Te6edf3to Te6edf3protoTb4b4b4.Te6edf3channelTff7b72!!Tb4b4b4.Te6edf3toOneLineStringTb4b4b4(Tb4b4b4)

Te6edf3protoTb4b4b4.Te6edf3clientNotification Tff7b72!Tff7b72= Tff7b72null Tff7b72-Tff7b72> Ta5d6ff"Ta5d6ffClientNotificationTa5d6ff" Te6edf3to Te6edf3protoTb4b4b4.Te6edf3clientNotificationTb4b4b4.Te6edf3toStringTb4b4b4(Tb4b4b4)

Tff7b72else Tff7b72-Tff7b72> Tff7b72return

Tb4b4b4}

Te6edf3insertMeshLogTb4b4b4(

Te6edf3MeshLogTb4b4b4(

Te6edf3uuid Tff7b72= Te6edf3UuidTb4b4b4.Te6edf3randomTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3toStringTb4b4b4(Tb4b4b4)Tb4b4b4,

Te6edf3message_type Tff7b72= Te6edf3typeTb4b4b4,

Te6edf3received_date Tff7b72= Te6edf3nowMillisTb4b4b4,

Te6edf3raw_message Tff7b72= Te6edf3messageTb4b4b4,

Te6edf3fromRadio Tff7b72= Te6edf3protoTb4b4b4,

Tb4b4b4)Tb4b4b4,

Tb4b4b4)

Tb4b4b4}

Tff7b72override Tff7b72fun Td2a8ffhandleReceivedMeshPacketTb4b4b4(Te6edf3packetTb4b4b4: Te6edf3MeshPacketTb4b4b4, Te6edf3myNodeNumTb4b4b4: Tffa657Int?Tb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3rxTime Tff7b72=

Tff7b72if Tb4b4b4(Te6edf3packetTb4b4b4.Te6edf3rx_time Tff7b72=Tff7b72= T79c0ff0Tb4b4b4) Tb4b4b4{

Te6edf3nowSecondsTb4b4b4.Te6edf3toIntTb4b4b4(Tb4b4b4)

Tb4b4b4} Tff7b72else Tb4b4b4{

Te6edf3packetTb4b4b4.Te6edf3rx_time

Tb4b4b4}

Tff7b72val Te6edf3preparedPacket Tff7b72= Te6edf3packetTb4b4b4.Te6edf3copyTb4b4b4(Te6edf3rx_time Tff7b72= Te6edf3rxTimeTb4b4b4)

Tff7b72if Tb4b4b4(Te6edf3nodeManagerTb4b4b4.Te6edf3isNodeDbReadyTb4b4b4.Te6edf3valueTb4b4b4) Tb4b4b4{

Te6edf3processReceivedMeshPacketTb4b4b4(Te6edf3preparedPacketTb4b4b4, Te6edf3myNodeNumTb4b4b4)

Tb4b4b4} Tff7b72else Tb4b4b4{

Te6edf3scopeTb4b4b4.Te6edf3launch Tb4b4b4{

Te6edf3earlyMutexTb4b4b4.Te6edf3withLock Tb4b4b4{

Tff7b72val Te6edf3queueSize Tff7b72= Te6edf3earlyReceivedPacketsTb4b4b4.Te6edf3size

Tff7b72if Tb4b4b4(Te6edf3queueSize Tff7b72>Tff7b72= Te6edf3maxEarlyPacketBufferTb4b4b4) Tb4b4b4{

Te6edf3LoggerTb4b4b4.Te6edf3w Tb4b4b4{ Ta5d6ff"Ta5d6ffEarly packet buffer full (Tffd700$Te6edf3queueSizeTa5d6ff), dropping oldest packetTa5d6ff" Tb4b4b4}

Te6edf3earlyReceivedPacketsTb4b4b4.Te6edf3removeFirstOrNullTb4b4b4(Tb4b4b4)

Tb4b4b4}

Te6edf3earlyReceivedPacketsTb4b4b4.Te6edf3addLastTb4b4b4(Te6edf3preparedPacketTb4b4b4)

Tb4b4b4}

Tff7b72private Tff7b72fun Td2a8ffflushEarlyReceivedPacketsTb4b4b4(Te6edf3reasonTb4b4b4: Tffa657StringTb4b4b4) Tb4b4b4{

Te6edf3scopeTb4b4b4.Te6edf3launch Tb4b4b4{

Tff7b72val Te6edf3packets Tff7b72=

Te6edf3earlyMutexTb4b4b4.Te6edf3withLock Tb4b4b4{

Tff7b72if Tb4b4b4(Te6edf3earlyReceivedPacketsTb4b4b4.Te6edf3isEmptyTb4b4b4(Tb4b4b4)Tb4b4b4) Tff7b72returnTf0883e@withLock Te6edf3emptyListTff7b72<Te6edf3MeshPacketTff7b72>Tb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3list Tff7b72= Te6edf3earlyReceivedPacketsTb4b4b4.Te6edf3toListTb4b4b4(Tb4b4b4)

Te6edf3earlyReceivedPacketsTb4b4b4.Te6edf3clearTb4b4b4(Tb4b4b4)

Te6edf3list

Tb4b4b4}

Tff7b72if Tb4b4b4(Te6edf3packetsTb4b4b4.Te6edf3isEmptyTb4b4b4(Tb4b4b4)Tb4b4b4) Tff7b72returnTf0883e@launch

Te6edf3LoggerTb4b4b4.Te6edf3d Tb4b4b4{ Ta5d6ff"Ta5d6ffreplayEarlyPackets reason=Tffd700$Te6edf3reasonTa5d6ff count=Tffd700${Te6edf3packetsTb4b4b4.Te6edf3sizeTffd700}Ta5d6ff" Tb4b4b4}

Tff7b72val Te6edf3myNodeNum Tff7b72= Te6edf3nodeManagerTb4b4b4.Te6edf3myNodeNumTb4b4b4.Te6edf3value

Te6edf3packetsTb4b4b4.Te6edf3forEach Tb4b4b4{ Te6edf3processReceivedMeshPacketTb4b4b4(Tffa657itTb4b4b4, Te6edf3myNodeNumTb4b4b4) Tb4b4b4}

Tb4b4b4}

Tf0883e@SuppressTb4b4b4(Ta5d6ff"Ta5d6ffLongMethodTa5d6ff"Tb4b4b4)

Tff7b72private Tff7b72fun Td2a8ffprocessReceivedMeshPacketTb4b4b4(Te6edf3packetTb4b4b4: Te6edf3MeshPacketTb4b4b4, Te6edf3myNodeNumTb4b4b4: Tffa657Int?Tb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3decoded Tff7b72= Te6edf3packetTb4b4b4.Te6edf3decoded Tff7b72?: Tff7b72return

Tff7b72val Te6edf3log Tff7b72=

Te6edf3MeshLogTb4b4b4(

Te6edf3uuid Tff7b72= Te6edf3UuidTb4b4b4.Te6edf3randomTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3toStringTb4b4b4(Tb4b4b4)Tb4b4b4,

Te6edf3message_type Tff7b72= Ta5d6ff"Ta5d6ffPacketTa5d6ff"Tb4b4b4,

Te6edf3received_date Tff7b72= Te6edf3nowMillisTb4b4b4,

Te6edf3raw_message Tff7b72= Te6edf3packetTb4b4b4.Te6edf3toStringTb4b4b4(Tb4b4b4)Tb4b4b4,

Te6edf3fromNum Tff7b72= Tff7b72if Tb4b4b4(Te6edf3packetTb4b4b4.Te6edf3from Tff7b72=Tff7b72= Te6edf3myNodeNumTb4b4b4) Te6edf3MeshLogTb4b4b4.Te6edf3NODE_NUM_LOCAL Tff7b72else Te6edf3packetTb4b4b4.Te6edf3fromTb4b4b4,

Te6edf3portNum Tff7b72= Te6edf3decodedTb4b4b4.Te6edf3portnumTb4b4b4.Te6edf3valueTb4b4b4,

Te6edf3fromRadio Tff7b72= Te6edf3FromRadioTb4b4b4(Te6edf3packet Tff7b72= Te6edf3packetTb4b4b4)Tb4b4b4,

Tb4b4b4)

Tff7b72val Te6edf3logJob Tff7b72= Te6edf3insertMeshLogTb4b4b4(Te6edf3logTb4b4b4)

Te6edf3scopeTb4b4b4.Te6edf3launch Tb4b4b4{

Te6edf3mapsMutexTb4b4b4.Te6edf3withLock Tb4b4b4{

Te6edf3logInsertJobByPacketIdTff7b72[Te6edf3packetTb4b4b4.Te6edf3idTff7b72] Tff7b72= Te6edf3logJob

Te6edf3logUuidByPacketIdTff7b72[Te6edf3packetTb4b4b4.Te6edf3idTff7b72] Tff7b72= Te6edf3logTb4b4b4.Te6edf3uuid

Tb4b4b4}

Te6edf3scopeTb4b4b4.Te6edf3handledLaunch Tb4b4b4{ Te6edf3serviceRepositoryTb4b4b4.Te6edf3emitMeshPacketTb4b4b4(Te6edf3packetTb4b4b4) Tb4b4b4}

Te6edf3myNodeNumTff7b72?.Te6edf3let Tb4b4b4{ Te6edf3myNum Tff7b72-Tff7b72>

Tff7b72val Te6edf3from Tff7b72= Te6edf3packetTb4b4b4.Te6edf3from

Tff7b72val Te6edf3isOtherNode Tff7b72= Te6edf3myNum Tff7b72!Tff7b72= Te6edf3from

Te6edf3nodeManagerTb4b4b4.Te6edf3updateNodeTb4b4b4(Te6edf3myNumTb4b4b4, Te6edf3withBroadcast Tff7b72= Te6edf3isOtherNodeTb4b4b4) Tb4b4b4{ Te6edf3nodeTb4b4b4: Te6edf3Node Tff7b72-Tff7b72>

Te6edf3nodeTb4b4b4.Te6edf3copyTb4b4b4(Te6edf3lastHeard Tff7b72= Te6edf3nowSecondsTb4b4b4.Te6edf3toIntTb4b4b4(Tb4b4b4)Tb4b4b4)

Tb4b4b4}

Te6edf3nodeManagerTb4b4b4.Te6edf3updateNodeTb4b4b4(Te6edf3fromTb4b4b4, Te6edf3withBroadcast Tff7b72= Tff7b72falseTb4b4b4, Te6edf3channel Tff7b72= Te6edf3packetTb4b4b4.Te6edf3channelTb4b4b4) Tb4b4b4{ Te6edf3nodeTb4b4b4: Te6edf3Node Tff7b72-Tff7b72>

Tff7b72val Te6edf3viaMqtt Tff7b72= Te6edf3packetTb4b4b4.Te6edf3via_mqtt Tff7b72=Tff7b72= Tff7b72true

Tff7b72val Te6edf3isDirect Tff7b72= Te6edf3packetTb4b4b4.Te6edf3hop_start Tff7b72=Tff7b72= Te6edf3packetTb4b4b4.Te6edf3hop_limit

Tff7b72var Te6edf3snr Tff7b72= Te6edf3nodeTb4b4b4.Te6edf3snr

Tff7b72var Te6edf3rssi Tff7b72= Te6edf3nodeTb4b4b4.Te6edf3rssi

Tff7b72if Tb4b4b4(Te6edf3isDirect Tff7b72&Tff7b72& Te6edf3packetTb4b4b4.Te6edf3isLoraTb4b4b4(Tb4b4b4) Tff7b72&Tff7b72& Tff7b72!Te6edf3viaMqttTb4b4b4) Tb4b4b4{

Te6edf3snr Tff7b72= Te6edf3packetTb4b4b4.Te6edf3rx_snr

Te6edf3rssi Tff7b72= Te6edf3packetTb4b4b4.Te6edf3rx_rssi

Tb4b4b4}

Tff7b72val Te6edf3hopsAway Tff7b72=

Tff7b72if Tb4b4b4(Te6edf3decodedTb4b4b4.Te6edf3portnum Tff7b72=Tff7b72= Te6edf3PortNumTb4b4b4.Te6edf3RANGE_TEST_APPTb4b4b4) Tb4b4b4{

T79c0ff0

Tb4b4b4} Tff7b72else Tff7b72if Tb4b4b4(Te6edf3viaMqttTb4b4b4) Tb4b4b4{

Tff7b72-T79c0ff1

Tb4b4b4} Tff7b72else Tff7b72if Tb4b4b4(Te6edf3packetTb4b4b4.Te6edf3hop_start Tff7b72=Tff7b72= T79c0ff0 Tff7b72&Tff7b72& Tb4b4b4(Te6edf3decodedTb4b4b4.Te6edf3bitfield Tff7b72?: T79c0ff0Tb4b4b4) Tff7b72=Tff7b72= T79c0ff0Tb4b4b4) Tb4b4b4{

Tff7b72-T79c0ff1

Tb4b4b4} Tff7b72else Tff7b72if Tb4b4b4(Te6edf3packetTb4b4b4.Te6edf3hop_limit Tff7b72> Te6edf3packetTb4b4b4.Te6edf3hop_startTb4b4b4) Tb4b4b4{

Tff7b72-T79c0ff1

Tb4b4b4} Tff7b72else Tb4b4b4{

Te6edf3packetTb4b4b4.Te6edf3hop_start Tff7b72- Te6edf3packetTb4b4b4.Te6edf3hop_limit

Tb4b4b4}

Te6edf3nodeTb4b4b4.Te6edf3copyTb4b4b4(

Te6edf3lastHeard Tff7b72= Te6edf3packetTb4b4b4.Te6edf3rx_timeTb4b4b4,

Te6edf3viaMqtt Tff7b72= Te6edf3viaMqttTb4b4b4,

Te6edf3lastTransport Tff7b72= Te6edf3packetTb4b4b4.Te6edf3transport_mechanismTb4b4b4.Te6edf3valueTb4b4b4,

Te6edf3snr Tff7b72= Te6edf3snrTb4b4b4,

Te6edf3rssi Tff7b72= Te6edf3rssiTb4b4b4,

Te6edf3hopsAway Tff7b72= Te6edf3hopsAwayTb4b4b4,

Tb4b4b4)

Tb4b4b4}

Tff7b72try Tb4b4b4{

Te6edf3routerTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3dataHandlerTb4b4b4.Te6edf3handleReceivedDataTb4b4b4(Te6edf3packetTb4b4b4, Te6edf3myNumTb4b4b4, Te6edf3logTb4b4b4.Te6edf3uuidTb4b4b4, Te6edf3logJobTb4b4b4)

Tb4b4b4} Tff7b72finally Tb4b4b4{

Te6edf3scopeTb4b4b4.Te6edf3launch Tb4b4b4{

Te6edf3mapsMutexTb4b4b4.Te6edf3withLock Tb4b4b4{

Te6edf3logUuidByPacketIdTb4b4b4.Te6edf3removeTb4b4b4(Te6edf3packetTb4b4b4.Te6edf3idTb4b4b4)

Te6edf3logInsertJobByPacketIdTb4b4b4.Te6edf3removeTb4b4b4(Te6edf3packetTb4b4b4.Te6edf3idTb4b4b4)

Tb4b4b4}

T8b949e/**

* Refreshes the local node's [Node.lastHeard] to prove the radio link is alive.

*

* Without this, [lastHeard] is only set when a [MeshPacket] arrives from another node (see

* [processReceivedMeshPacket]). On a quiet mesh the heartbeat cycle still exchanges data with the firmware (ToRadio

* heartbeat → FromRadio queueStatus every 30 s), but that data never touched [lastHeard], causing the local node to

* appear stale in the UI even though the connection is healthy.

*

* To avoid flooding the DB on high-frequency variants (log records arrive many times per second when debug logging

* is enabled), writes are throttled to at most once per [LOCAL_NODE_REFRESH_INTERVAL_MS].

*/

Tff7b72private Tff7b72fun Td2a8ffrefreshLocalNodeLastHeardTb4b4b4(Tb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3now Tff7b72= Te6edf3nowMillis

Tff7b72if Tb4b4b4(Te6edf3now Tff7b72- Te6edf3lastLocalNodeRefreshMs Tff7b72< Te6edf3LOCAL_NODE_REFRESH_INTERVAL_MSTb4b4b4) Tff7b72return

Te6edf3lastLocalNodeRefreshMs Tff7b72= Te6edf3now

Tff7b72val Te6edf3myNum Tff7b72= Te6edf3nodeManagerTb4b4b4.Te6edf3myNodeNumTb4b4b4.Te6edf3value Tff7b72?: Tff7b72return

Te6edf3nodeManagerTb4b4b4.Te6edf3updateNodeTb4b4b4(Te6edf3myNumTb4b4b4, Te6edf3withBroadcast Tff7b72= Tff7b72falseTb4b4b4) Tb4b4b4{ Te6edf3nodeTb4b4b4: Te6edf3Node Tff7b72-Tff7b72> Te6edf3nodeTb4b4b4.Te6edf3copyTb4b4b4(Te6edf3lastHeard Tff7b72= Te6edf3nowSecondsTb4b4b4.Te6edf3toIntTb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4}

Tb4b4b4}

Tff7b72private Tff7b72fun Td2a8ffinsertMeshLogTb4b4b4(Te6edf3logTb4b4b4: Te6edf3MeshLogTb4b4b4)Tb4b4b4: Te6edf3Job Tff7b72= Te6edf3scopeTb4b4b4.Te6edf3handledLaunch Tb4b4b4{ Te6edf3meshLogRepositoryTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3insertTb4b4b4(Te6edf3logTb4b4b4) Tb4b4b4}

Tff7b72companion Tff7b72object Tb4b4b4{

T8b949e/**

* Minimum interval between local-node `lastHeard` DB writes, in milliseconds. Aligned with the heartbeat

* interval (30 s) so that one write per heartbeat cycle keeps the node fresh without unnecessary DB churn.

*/

Tff7b72private Tff7b72const Tff7b72val Te6edf3LOCAL_NODE_REFRESH_INTERVAL_MS Tff7b72= T79c0ff3T79c0ff0Te6edf3_000L

Tb4b4b4}